package cn.me.alphamq.common.entity.resp;

import cn.me.alphamq.common.entity.BaseMsg;

/**
 * 消费成功的响应对象
 *
 * @author f
 */
public class ConsumeSuccessResp extends BaseMsg {

    /**
     * 返回 ack 的状态
     *
     * @see cn.me.alphamq.common.enumeration.AckStatusEnum
     */
    private Integer ackStatus;

    public ConsumeSuccessResp() {
    }

    public ConsumeSuccessResp(String msgId, Integer ackStatus) {
        super(msgId);
        this.ackStatus = ackStatus;
    }

    public Integer getAckStatus() {
        return ackStatus;
    }

    public void setAckStatus(Integer ackStatus) {
        this.ackStatus = ackStatus;
    }
}
